package cn.itcast.czxy.BD18

import cn.itcast.czxy.BD18.bean.BaseMode
import org.apache.spark.sql.DataFrame

object Marriage extends BaseMode{
  override def setAppName: String = "Marriage"

  override def setLeven4Id: Int = 100

  override def getNewTag(leve5: DataFrame, hbaseDF: DataFrame): DataFrame = {
    leve5.join(hbaseDF,leve5("rule")===hbaseDF("marriage")).select(hbaseDF("id").as("userId"),leve5("id").as("tagsId"))
  }

  def main(args: Array[String]): Unit = {
    exec()
  }
}
